package com.aliyun.messagemgt.application.service.mq;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 消息队列配置类
 *
 * @author changcong
 */
@Component
public class BusMqConfig {
    
    //@Value("${MQ.rocket.consumerId}")
    private String groupId;
    //@Value("${MQ.rocket.accessKey}")
    private String accessKey;
    //@Value("${MQ.rocket.secretKey}")
    private String secretKey;
    //@Value("${MQ.rocket.ONSAddr}")
    private String onsAddr;
    //@Value("${MQ.rocket.topic}")
    private String topic;

    /**
     * 提供消费者的配置
     */
//    public Properties getConsumerProperties() {
//        Properties consumerProperties = new Properties();
//        consumerProperties.setProperty(PropertyKeyConst.ConsumerId, groupId);
//        consumerProperties.setProperty(PropertyKeyConst.AccessKey, accessKey);
//        consumerProperties.setProperty(PropertyKeyConst.SecretKey, secretKey);
//        consumerProperties.setProperty(PropertyKeyConst.ONSAddr, onsAddr);
//        consumerProperties.setProperty(PropertyKeyConst.MessageModel, PropertyValueConst.CLUSTERING);
//        return consumerProperties;
//    }

}
